package com.iot.service.mqtt.bridge;

import com.iot.service.mqtt.model.request.TlMqttPublishReq;

/**
 * @Author: hszhou
 * @Date: 2025/5/12 8:37
 * @Description: 抽象数据桥接接口 用户通知各个数据处理者处理数据
 */
public abstract class AbstractBridgeObserver {



    /**
     * 用于发送数据
     * @author hszhou
     * @datetime: 2025-05-12 14:42:46
     * @param clientId 发送的客户端
     * @param qos 发送的qos等级
     * @param req  消息体
     **/
    protected abstract void forward(String clientId,int qos,TlMqttPublishReq req);
}
